package com.kloooong.top.push;

import com.alibaba.fastjson.JSONObject;
import com.dingteam.push.api.channel.OrgSuiteAuthChannel;
import com.dingteam.push.api.channel.OrgSuiteAuthInput;
import com.dingteam.push.api.channel.OrgUserChannel;
import com.dingteam.push.api.channel.OrgUserInput;
import com.dingteam.push.api.message.OrgSuiteAuthMessage;
import com.dingteam.push.api.message.OrgUserMessage;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

@Component
@EnableBinding(OrgUserChannel.class)
public class BizId13 {


    @StreamListener(target = OrgUserInput.INPUT ,condition = "headers['syncAction']=='user_leave_org' and headers['suiteId']=='"+Contain.stuidId666+"'")
    public void suid666(OrgUserMessage orgUser) {
        System.out.println("666 13 data is coming 。。。");
        System.out.println("data："+ JSONObject.toJSONString(orgUser));
    }


    @StreamListener(target = OrgUserInput.INPUT ,condition = "headers['syncAction']=='user_leave_org' and headers['suiteId']=='"+Contain.stuidId666+"'")
    public void suid777(OrgUserMessage orgUser) {
        System.out.println("777 13 data is coming 。。。");
        System.out.println("data："+ JSONObject.toJSONString(orgUser));
    }



}
